package com.sdp.irrigation.server.property;

import java.util.Map;

//import org.springframework.boot.context.properties.ConfigurationProperties;
//import org.springframework.stereotype.Component;

//@Component
//@ConfigurationProperties(prefix = "ychl.kafka.topic")
public class KafkaProperty {

	private String produceLogPrefix;//日志kafka主题前缀
	
	private int produceDefaultPartition;//日志主题默认分区数
	
	private Map<String, Integer> produceDefinePartition;//日志主题自定义分区数
	
	private String consumerReplyPrefix;//消费应答主题前缀
	
	private String consumerCommandPrefix;//消费命令下发主题前缀

	public String getProduceLogPrefix() {
		return produceLogPrefix;
	}

	public void setProduceLogPrefix(String produceLogPrefix) {
		this.produceLogPrefix = produceLogPrefix;
	}

	public int getProduceDefaultPartition() {
		return produceDefaultPartition;
	}

	public void setProduceDefaultPartition(int produceDefaultPartition) {
		this.produceDefaultPartition = produceDefaultPartition;
	}

	public Map<String, Integer> getProduceDefinePartition() {
		return produceDefinePartition;
	}

	public void setProduceDefinePartition(Map<String, Integer> produceDefinePartition) {
		this.produceDefinePartition = produceDefinePartition;
	}

	public String getConsumerReplyPrefix() {
		return consumerReplyPrefix;
	}

	public void setConsumerReplyPrefix(String consumerReplyPrefix) {
		this.consumerReplyPrefix = consumerReplyPrefix;
	}

	public String getConsumerCommandPrefix() {
		return consumerCommandPrefix;
	}

	public void setConsumerCommandPrefix(String consumerCommandPrefix) {
		this.consumerCommandPrefix = consumerCommandPrefix;
	}
	
}
